e2dbfe0486bec03a2625cdb9abe237224cf45066,joker-engine/src/test/java/cs/bilkent/joker/engine/tuplequeue/impl/queue/MultiThreadedTupleQueueTest.java,MultiThreadedTupleQueueTest,shouldOfferTupleExceedinglyWithTimeoutWhenCapacityIncreases,#,63

Before Change


    public void shouldOfferTupleExceedinglyWithTimeoutWhenCapacityIncreases () throws InterruptedException
    {
        queue.offerTuple( newTuple( 1 ) );
        queue.offerTuple( newTuple( 2 ) );
        queue.offerTuple( newTuple( 3 ) );

        final Thread thread = spawnThread( increaseCapacity( Thread.currentThread(), 4 ) );

After Change


    @Test
    public void shouldOfferEmptyTuplesWithTimeout ()
    {
        final int offered = queue.offerTuples( asList( newTuple( 1 ), newTuple( 2 ) ), 2, TIMEOUT_IN_MILLIS, MILLISECONDS );

        assertEquals( 0, offered );
    }